const Service = require("egg").Service;

class WxtranspayService extends Service {
  // 记录转账事件
  async create(data) {
    const { ctx } = this;
    const savedata = {
      wxid: data.wxid, // 当前登录的微信id
      port: data.port, // httpapi 监听端口号
      pid: data.pid, // 进程号
      flag: data.flag, // websocket 监听端口号
      fromWxid: data.data.fromWxid, // 对方wxid
      msgSource: data.data.msgSource,
      transType: data.data.transType, // 1|即时到账 2|延时到账
      money: data.data.money,
      memo: data.data.memo, // 转账备注
      transferid: data.data.transferid, // 转账ID
      transcationid: data.data.transcationid, // 转账ID
      invalidtime: data.data.invalidtime, // 10位时间戳
      msgId: data.data.msgId, // 消息 ID（可选）
      timestamp: data.timestamp, // 收到这条消息的13位现行时间戳
      date: new Date(Number(data.timestamp) + 8 * 60 * 60 * 1000),
    };

    try {
      const result = await ctx.model.Wxtranspay.create(savedata);
      return result;
    } catch (err) {
      this.ctx.logger.error("保存转账事件失败:", err);
      return null;
    }
  }

  //   更新转账事件
  async update(id, data) {}
}
module.exports = WxtranspayService;
